// 聊天类
import {
	getStorage,
	setStorage
} from '@/lib/storage.js'
import $S from '@/server/server.js'
import useUser from '@/pinia/user.js'
import useMoment from '@/pinia/moment'
import {
	ref
} from 'vue'
import { Http } from '@/config/config'


class chat {
	constructor(options) {
		this.socket = null // websocket连接对象
		this.isOnline = false // 当前用户是否在线
		this.url = options.url // websocket地址
		this.TO = null; //当前的聊天对象 
		this.reSocketNum = 0
		this.user = getStorage('userinfo') // 获得当前用户的信息
		if (this.user.token) { // 连接websocket服务器
			this.connectWebsocket()
		}
	}
	// 连接socket
	connectWebsocket() {
		this.socket = uni.connectSocket({
			url: this.url + "?token=" + this.user.token,
			success: () => {}
		})
		// 监听连接成功
		this.socket.onOpen(() => this.onOpen())
		// 监听接收信息
		this.socket.onMessage((res) => this.onMessage(res))
		// 监听断开
		this.socket.onClose(() => this.onClose())
		// 监听错误
		this.socket.onError(() => this.onError())
	}
	// 连接成功
	onOpen() {
		this.reSocketNum = 0
		this.isOnline = true
		console.log('连接成功');
	}
	// 接收到消息
	onMessage(message) {
		const res = JSON.parse(message.data)
		console.log('接收到了消息',res);
		switch (res.data.msg) {
			// 接收到的错误的消息
			case 'fail':
				return uni.showToast({
					title: res.data,
					icon: 'none'
				});
			break;
			case 'moment':
				// 朋友圈消息
				console.log('朋友圈消息')
				this.handMomentMessage(res.data.message)
			break;
				// 成功的处理
			case 'ok':
				this.handleOnMessage(res.data.message)
			break;
		}
	}
	// 处理接受到的朋友圈消息
	handMomentMessage(message){
		console.log('接收到了朋友圈消息');
		// console.log(message);
		const momentStore = useMoment()
		momentStore.setMomentMessage(message)
	}
	// 接收到消息的处理
	handleOnMessage(message) {
		console.log('接收到了消息');
		console.log(message);
		// 1. 存储在本地
		const {
			data
		} = this.addHistoryRecord(message, false)
		// 2. 更新回话列表
		this.updateChatList(message, false)
		// 3. 通知对方的会话列表更新
		uni.$emit('onMessage', message)
	}
	// 断开连接
	onClose() {
		// 1. 用户下线
		this.isOnline = false
		this.socket = null
		// 2. 断线重连
		console.log('断开连接');
	}
	// 连接错误
	onError() {
		this.isOnline = false
		this.socket = null
		console.log('连接发送错误');
		// 重新连接
		this.reConnect()
	}
	reConnect(){
		if(this.reSocketNum <= 3){ // 自动重连
			console.log('自动重连第' + this.reSocketNum + '次');
			this.connectWebsocket()
		}else{
			this.reconnectConfirm()
		}
	}
	reconnectConfirm() {
		uni.showModal({
			content: '你已经断线，是否重新连接？',
			confirmText: "重新连接",
			success: (res) => {
				if (res.confirm) {
					this.connectWebsocket()
				}
			}
		});
	}
	// 创建聊天对象
	createChatObj(params) {
		/*
			id: 好友id或群id
			name: 接收人/群 名称
			avatar: 好友头像或者群头像
			chat_type: 群聊group或私聊user
		**/
		this.TO = params
		console.log('创建聊天对象', this.TO);
	}
	// 重置当前聊天对象
	closeTo() {
		this.TO = null
	}
	// 组织信息格式
	formatSendData(params) {
		return {
			id: 0, // 唯一id，后端生成，用于撤回指定消息
			from_avatar: this.user.avatar, // 发送者头像
			from_name: this.user.nickname || this.user.username, // 发送者昵称
			from_id: this.user.id, // 发送者id
			to_id: params.to_id || this.TO.id, // 接收人/群 id
			to_name: params.to_name || this.TO.name, // 接收人/群 名称
			to_avatar: params.to_avatar || this.TO.avatar, // 接收人/群 头像
			chat_type: params.chat_type || this.TO.chat_type, // 接收类型
			type: params.type, // 消息类型
			data: params.data, // 消息内容
			options: params.options ? params.options : {}, // 其他参数
			create_time: (new Date()).getTime(), // 创建时间
			isremove: 0, // 是否撤回
			sendStatus: "pending" // 发送状态，success发送成功,fail发送失败,pending发送中
		}
	}
	// 上传文件
	upload(flies){
		const token = uni.getStorageSync('token').replace(/"/g, '');
		const urlList = []
		return new Promise((resolve,reject) => {
			flies.forEach((item,index) => {
				uni.uploadFile({
					url: Http + '/upload',
					filePath: item,
					name: 'files',
					header:{
						token:token
					},
					success(res) {
						res = JSON.parse(res.data)
						// console.log('上传',res);
						urlList.push(res.data)
						if(urlList.length === flies.length){
							resolve(urlList)
						}
					},
					fail(err) {
						console.log('上传失败');
						console.log(err);
					}
				})
			})
		})
		return res(urlList)
	}
	// 发送消息
	send(message) {
		return new Promise((resolve, reject) => {
			// 1. 添加消息历史记录
			const {
				k
			} = this.addHistoryRecord(message)
			// 2. 更新会话列表
			const list = this.updateChatList(message)
			// 3. 检验用户是否在线 没在线则提示重连
			// if (!this.checkOnline()) return reject('未上线')
			// 4. 发送消息
			$S.post('/chat/send', {
				to_id: message.to_id || this.TO.id,
				chat_type: message.chat_type || this.TO.chat_type,
				type: message.type,
				data: message.data,
				options: JSON.stringify(message.options)
			}, {
				token: true
			}).then(res => {
				message.id = res.id
				message.sendStatus = 'success'
				// 更新指定历史记录
				this.updateChatDetail(message, k)
				resolve(message)
			}).catch(err => {
				message.sendStatus = 'fail'
				// 更新指定历史记录
				this.updateChatDetail(message, k)
				reject(message)
			})
		})
	}
	
	// 删除聊天中的某一条消息
	deleteChatMessage(message){
		let key = `chatDetail_${this.user.id}_${message.chat_type}_${message.to_id}`
		let list = this.getChatDetail(key) ? this.getChatDetail(key) : []
		const index = list.findIndex(f => f.create_time === message.create_time)
		console.log(list[index]);
		list.splice(index,1)
		setStorage(key, list)
		uni.$emit('onMessage', message)
	}
	
	// 更新指定历史记录
	async updateChatDetail(message, k, isSend = true) {
		// 获取对方id
		let id = message.chat_type === 'user' ? (isSend ? message.to_id : message.from_id) : message.to_id
		// key值：chatDetail_当前用户id_会话类型_接收人/群id
		let key = `chatDetail_${this.user.id}_${message.chat_type}_${id}`
		// 获取原来的聊天记录
		let list = this.getChatDetail(key) ? this.getChatDetail(key) : []
		// 根据k查找对应聊天记录
		let index = list.findIndex(item => item.k === k)
		if (index === -1) return;
		list[index] = message
		// 存储
		setStorage(key, list)
	}
	/**
	 * 添加到历史记录
	 * @param {Object} message - 聊天消息
	 * @param {Boolean} isSend - 是否为发送者
	 */
	addHistoryRecord(message, isSend = true) {
		// 1. 获取对方id
		let id = message.chat_type === 'user' ? (isSend ? message.to_id : message.from_id) : message.to_id
		// 2. 存放缓存的key值：chatDetail_当前用户id_会话类型_接收人/群id
		let key = `chatDetail_${this.user.id}_${message.chat_type}_${id}`
		// 3. 读取缓存
		let list = this.getChatDetail(key) ? this.getChatDetail(key) : []
		// 3. 添加标识 后续修改消息状态
		message.k = 'k' + list.length
		list.push(message)
		// 4. 重新设置缓存
		setStorage(key, list)
		return {
			data: message,
			k: message.k
		}
	}

	// 会话列表的中发送的消息和接受的消息展示的格式
	formatChatItemData(message, isSend) {
		let data = message.data
		switch (message.type) {
			case 'emo':
				data = '[表情]'
				break;
			case 'image':
				data = '[图片]'
				break;
			case 'audio':
				data = '[语音]'
				break;
			case 'video':
				data = '[视频]'
				break;
			case 'card':
				data = '[名片]'
				break;
		}
		data = isSend ? data : `${message.from_name}: ${data}`
		return data
	}

	/**
	 * 更新会话列表 
	 * @param {Object} message - 聊天消息
	 * @param {Boolean} isSend - 是否为发送者    
	 */
	async updateChatList(message, isSend = true) {
		// 1. 获得本地存储会话列表
		let list = this.getChatList() ? this.getChatList() : []
		// 2. 记录是否处于当前聊天中  如果是发送消息后就不会跟新角标
		let isCurrentChat = false
		// 3. 接收人/群 id/头像/昵称
		let id = 0
		let avatar = ''
		let name = ''
		// 4. 判断私聊还是群聊
		if (message.chat_type === 'user') { // 私聊
			// 聊天对象是否存在
			isCurrentChat = this.TO ? (isSend ? this.TO.id === message.to_id : this.TO.id === message.from_id) : false

			id = isSend ? message.to_id : message.from_id
			avatar = isSend ? message.to_avatar : message.from_avatar
			name = isSend ? message.to_name : message.from_name
		} else { // 群聊
			isCurrentChat = this.TO && (this.TO.id === message.to_id)
			id = message.to_id
			avatar = message.to_avatar
			name = message.to_name
		}
		// 5. 会话是否存在 不存在则创建到头部 存在则更新提前到头部
		const index = list.findIndex(item => {
			return item.chat_type === message.chat_type && item.id === id
		})
		// 6. 未读数是否 + 1
		const noreadnum = (isSend || isCurrentChat) ? 0 : 1
		// 消息的展示格式
		const lastData = this.formatChatItemData(message,isSend)
		// console.log('最后一条消息',lastData);
		if (index !== -1) { // 存在
			// 拿到当前会话
			let item = list[index]
			// 更新该会话最后一条消息时间，内容，类型
			item.update_time = (new Date()).getTime()
			item.name = name
			item.data = lastData
			item.avatar = avatar
			item.type = message.type
			// 未读数更新
			item.noreadnum += noreadnum
			// 置顶会话
			list = this.listToFirst(list, index)
		} else { // 不存在
			let chatItem = {
				id, // 接收人/群 id
				chat_type: message.chat_type, // 接收类型 user单聊 group群聊
				avatar, // 接收人/群 头像
				name, // 接收人/群 昵称
				update_time: (new Date()).getTime(), // 最后一条消息的时间戳
				data: lastData, // 最后一条消息内容
				type: message.type, // 最后一条消息类型
				noreadnum, // 未读数
				istop: false, // 是否置顶
				shownickname: false, // 是否显示昵称
				nowarn: false, // 消息免打扰
				strongwarn: false, // 是否开启强提醒
				isTopping: false // 是否置顶
			}
			// 群聊
			if (message.chat_type === 'group' && message.group) {
				chatItem.shownickname = true
				chatItem.name = message.to_name
				chatItem = {
					...chatItem,
					user_id: message.group.user_id, // 群管理员id
					remark: "", // 群公告
					invite_confirm: 1, // 邀请确认
				}
			}
			list.unshift(chatItem)
		}
		// 7. 存储
		let key = `chatlist_${this.user.id}`
		setStorage(key, list)
		// 8. 更新未读数
		await this.updateBadge()
		// 9. 通知更新pinia中的聊天会话列表
		const userStore = useUser()
		userStore.updateChatList(list)
		return list
	}
	// 删除某一个会话列表
	deleteChatListLitem(id,chat_type){
		// 1. 获得本地存储会话列表
		let list = this.getChatList() ? this.getChatList() : []
		// 2. 找到要删除的那一项
		let index = list.findIndex(item=>item.id === id && item.chat_type === chat_type)
		if(index !== -1){ // 找到了
			// 3. 删除
			list.splice(index,1)
			// 4. 重新存储
			let key = `chatlist_${this.user.id}`
			setStorage(key, list)
			// 5. 更新未读数
			this.updateBadge()
			// 6. 通知更新pinia中的聊天会话列表
			const userStore = useUser()
			userStore.updateChatList(list)
		}
	}
	
	// 置顶聊天
	toppingChat(id) {
		console.log(id);
		// 获取所有会话列表
		let list = this.getChatList() ? this.getChatList() : []
		const index = list.findIndex(f => f.id === id)
		if (index != -1) {
			list.unshift(list.splice(index, 1)[0]);
			list[0].isTopping = true
		}
		//  存储
		let key = `chatlist_${this.user.id}`
		setStorage(key, list)
		// 通知更新pinia中的聊天会话列表
		const userStore = useUser()
		userStore.updateChatList(list)
	}
	// 取消置顶
	cancelToppingChat(id) {
		// 拿到置顶的个数
		let topiingNum = 0
		let list = this.getChatList() ? this.getChatList() : []
		list.forEach(f => {
			if (f.isTopping) {
				topiingNum += topiingNum
			}
		})
		// 找到取消置顶的哪一个
		const index = list.findIndex(f => f.id === id)
		list[index].isTopping = false
		const oldItem = list.splice(index, 1)[0]
		list.splice(topiingNum, 0, oldItem)
		//  存储
		let key = `chatlist_${this.user.id}`
		setStorage(key, list)
		// 通知更新pinia中的聊天会话列表
		const userStore = useUser()
		userStore.updateChatList(list)
	}
	// 更新未读数
	async updateBadge(list = false) {
		// 获取所有会话列表
		list = list ? list : this.getChatList() ? this.getChatList() : []
		// 统计所有未读数
		let total = 0
		list.forEach(item => {
			total += item.noreadnum
		})
		// 设置底部导航栏角标
		if (total > 0) {
			uni.setTabBarBadge({
				index: 0,
				text: total <= 99 ? total + '' : '99+'
			})
		} else {
			uni.removeTabBarBadge({
				index: 0
			})
		}
	}
	// 获取本地存储会话列表
	getChatList() {
		let key = `chatlist_${this.user.id}`
		return getStorage(key)
	}
	// 获取聊天记录
	getChatDetail(key = false) {
		key = key ? key : `chatDetail_${this.user.id}_${this.TO.chat_type}_${this.TO.id}`
		return getStorage(key)
	}
	// 数组置顶
	listToFirst(arr, index) {
		let topiingNum = 0
		arr.forEach(f => {
			if (f.isTopping) {
				topiingNum += 1
			}
		})
		if (index != 0) {
			if (topiingNum === 0) {
				arr.unshift(arr.splice(index, 1)[0])
			} else {
				let oldItem = arr.splice(index, 1)[0]
				arr.splice(topiingNum, 0, oldItem)
			}
		}
		return arr;
	}
}
export default chat